let MongoClient = require( 'mongodb' ).MongoClient;

// 新增一个管理员
const createAdministrator = db => {
  if( !db.addUser )  throw Error( '在party数据库中往admin数据库里面增加一个管理员, 疯了吧你' );


  db.addUser(
    'linyuzhao',
    'zhao@123',
    {
      roles: [ 'userAdminAnyDatabase' ]
    }
  ).then( res => {
    console.log(res, '增加的结果是 res');

  } );
  // db.createUser(
  //   {
  //     user: "linyuzhao",
  //     pwd: "zhao@123",
  //     roles: [ { role: "userAdminAnyDatabase", db: "admin" } ]
  //   }
  // )

};



// 用于操作数据库
const main = () => {
  let url = 'mongodb://47.97.6.69:27017';

    MongoClient.connect( url, ( err, client ) => {
      if ( err )  throw Error( '连接数据库发生错误' );

      let db = client.db('admin');
      if ( !db ) throw Error( '选择数据库 "party" 发生错误' );

      // 增加一个管理员
      createAdministrator(db);
      // db.addUser( 'linyuzhao', 'zhao@123', {
      //
      // } );

      // console.log(db, '数据库');

      // 把 db 保存到全局
      // let testCol = db.collection('test');

      // testCol.insertMany( [{
      //   name: 'zhao'
      // },{
      //   name: 'xiaoming'
      // }] ).then( res => {
      //   console.log(res, '输入结果');
      // } );

      // testCol
      //   .find({})
      //   .toArray(function(err, items) {
      //     console.log(items, '查找结果');
      //   } );

      // db.collection('test').find({}).toArray(function(err, items) {
      //   console.log(items, '结果');
      // } );
      //
      //  "a": 1
      // }).then( (one)=> {
      // console.log( one, 'one');
      // console.log( two, 'two');
      // } );

      // console.log(client, '没有, 问题, 成功链接');
      // 唯一存储花旦年会数据库的地方, 后面都会用到
      // setDb( db );
    } );

};

main();
